﻿using EFFC.Frame.Net.Module.Extend.Mqtt.Attributes;
using ICPFrameLib.Business;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace XHRPMIS.Business.Mqtt
{
    public class ClientSample : MyMqttClientLogic
    {
        [MqttSubscribe("test")]
        public object DoSample()
        {
            CurrentClient.PublishAsync("sample", new { code = "success", msg = $"这是个sample,from {CurrentClientID}" });
            return "这是个sample";
        }
    }
}
